package io.kiki.stack.netty.channelManager;

import io.kiki.stack.netty.config.Config;
import io.kiki.stack.netty.protocol.CodecImpl;
import io.kiki.stack.netty.userProcessor.UserProcessor;
import lombok.Getter;
import lombok.Setter;
import lombok.extern.slf4j.Slf4j;

import java.util.concurrent.ConcurrentHashMap;

@Slf4j
@Setter
@Getter
public class ClientChannelFactory extends DefaultChannelFactory {

    public ClientChannelFactory(ConcurrentHashMap<String, UserProcessor<?>> userProcessors, Config configurations) {//
        super(new CodecImpl(), new HeartbeatHandler(), new ChannelInboundHandlerAdapter(false, userProcessors), configurations);
    }
}